package com.wu.spark

import java.sql.{Driver, DriverManager}

object SparkSqlThriftServerApp {

  def main(args: Array[String]): Unit = {

   Class.forName("");
    val  conn = DriverManager.getConnection("","","");
    val pstmt = conn.prepareStatement("select * from emp");
    val rs = pstmt.executeQuery();
  while (rs.next())
  {
    print(rs.getInt("id"));
  }
    rs.close();
    pstmt.close();
    conn.close();


  }

}
